package cn.com.zetatech.loader.resolver.service;

import cn.com.zetatech.loader.entity.ParquetMessage;
import cn.com.zetatech.loader.util.AnnotationParquetType;
import org.springframework.stereotype.Component;

/**
 * @author jian.chen@zetatech.com.cn
 * @Description TODO
 * @Date 2024/8/27 11:33
 */
@AnnotationParquetType("TYPE_A")
@Component
public class AnnotationTypeAFunctionAnnotation implements AnnotationParquetFunction {
    @Override
    public void process(ParquetMessage message) {
        // 处理 TYPE_A 类型的消息
        System.out.println("Processing TYPE_A: " + message);
    }

    @Override
    public String getType() {
        return "TYPE_A";
    }
}


